package dailearn.stream.input;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;

/**
 * @author daify
 * @date 2019-07-14
 */
@EnableBinding(GetMessage.class)
public class GetMessageService {


    @StreamListener(GetMessage.NAME)
    public void messageInPut(Message<String> message) {
        System.err.println(" 消息接收成功：" + message.getPayload());
    }

}
